package com.spring.webflux.reactive;

import reactor.core.publisher.Flux;

/**
 * <pre>
 * 功能描述：
 * </pre>
 *
 * @author: 李明杰
 * @date: 2024/3/12 20:39
 */
public class Flux_BasicStudy {
    public static void main(String[] args) {
        var flux = Flux.range(1, 7)
                .doOnComplete(() -> System.out.println("Completed"))
                .doOnNext(integer -> System.out.println("doOnNext=>" + integer));
        flux.subscribe();
    }
}
